package com.fafi.rxjava1.subscribeon;



public class NewThreadSwitcher extends Switcher {
    private String threadName;

    public Switcher setThreadName(String threadName) {
        this.threadName = threadName;
        return this;
    }

    @Override
    public Worker createWorker() {
        NewThreadWorker worker = new NewThreadWorker();
        worker.setThreadName(threadName);
        return worker;
    }
}